9e3c97882d32856f1e1bace5382b78a6203191c1,fcrepo-reindexing/src/main/java/org/fcrepo/camel/reindexing/RestProcessor.java,RestProcessor,process,#Exchange#,57

Before Change


        final Message in = exchange.getIn();

        final String path = in.getHeader(Exchange.HTTP_PATH, "", String.class);
        final String contentType = in.getHeader(Exchange.CONTENT_TYPE, "", String.class);
        final String body = in.getBody(String.class);
        final Set<String> endpoints = new HashSet<>();

        for (final String s : in.getHeader(ReindexingHeaders.RECIPIENTS, "", String.class).split(",")) {
            endpoints.add(s.trim());
        }

After Change


        final String body = in.getBody(String.class);
        final Set<String> endpoints = new HashSet<>();

        for (final String s : in.getHeader(REINDEXING_RECIPIENTS, "", String.class).split(",")) {
            endpoints.add(s.trim());
        }